// 需要使用第三方插件ws

// 引入ws模块
const WebSocket = require('ws');

// 将webscoket服务启动在8080端口
const wss = new WebSocket.WebSocketServer({ port: 8080 });

// 监听连接
wss.on('connection', function connection(ws) {
  // ws是单个的前端的连接
  ws.on('error', console.error);

  // 监听接受前端发来的信息
  ws.on('message', function message(data) {
    // console.log('received: %s', data);
    // ws.send(data + "");

    // 用来做广播
    // wss.clients所有连接的前端
    wss.clients.forEach(function each(client) {
      if (client.readyState === WebSocket.OPEN) {
        client.send(data + "");
      }
    });
  });

  // 向前端发送
  // ws.send('something');
});